read = true;
synchronized (myTextBuffer) {
processLine(buffer, token, n);
}
myScheduledSubmitter = myExecutorService.submit(myTokenSubmitter);
int n;
while ((n = myReader.read(buffer)) > 0) {
read = true;
processLine(buffer, line, n);
}
if (line.length() > 0) {